Rhea の使用

Red Hat build of Rhea 3.0

JavaScript を使用した AMQ メッセージングクライアントの開発

概要

このガイドでは、他の AMQ コンポーネントでクライアントをインストールして使用する方法を説明します。

多様性を受け入れるオープンソースの強化
リンクのコピー

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。まずは、マスター (master)、スレーブ (slave)、ブラックリスト (blacklist)、ホワイトリスト (whitelist) の 4 つの用語の置き換えから始めます。この取り組みは膨大な作業を要するため、今後の複数のリリースで段階的に用語の置き換えを実施して参ります。詳細は、Red Hat CTO である Chris Wright のメッセージをご覧ください。

第1章概要
リンクのコピー

Rhea は、メッセージングアプリケーションを開発するためのライブラリーです。また、AMQP メッセージを送受信する JavaScript アプリケーションを作成できます。

Red Hat build of Rhea は、複数の言語やプラットフォームをサポートするメッセージングライブラリースイートである AMQ Clients の一部です。利用可能なクライアントの詳細は、AMQ クライアントを参照してください。

Red Hat build of Rhea は、Rhea メッセージングライブラリーに基づいています。詳細な API ドキュメントは、Rhea API リファレンスを参照してください。

1.1. 主な特長
リンクのコピー

既存のアプリケーションとの統合を簡素化するイベント駆動型の API
セキュアな通信用の SSL/TLS
柔軟な SASL 認証
自動再接続およびフェイルオーバー
AMQP と言語ネイティブのデータ型間のシームレスな変換
AMQP 1.0 の全機能へのアクセス

1.2. サポートされる標準およびプロトコル
リンクのコピー

Red Hat build of Rhea は、以下の業界標準およびネットワークプロトコルをサポートします。

Advanced Message Queueing Protocol (AMQP) のバージョン 1.0
SSL の後継である TLS (Transport Layer Security) プロトコルのバージョン 1.0、1.1、1.2、および 1.3
Simple Authentication and Security Layer (SASL) メカニズム ANONYMOUS、PLAIN、EXTERNAL
IPv6 での最新の TCP

1.3. サポートされる構成
リンクのコピー

Red Hat build of Rhea でサポートされている設定に関する最新情報は、Red Hat Customer Portal で Red Hat AMQ でサポートされる設定を参照してください。

1.4. 用語および概念
リンクのコピー

このセクションでは、コア API エンティティーを紹介し、コア API が連携する方法を説明します。

Expand

表1.1 API の用語
エンティティー	説明
Container	接続の最上位のコンテナー。
Connection	ネットワーク上の 2 つのピア間の通信チャネル。これにはセッションが含まれます。
Session	メッセージの送受信を行うためのコンテキスト。送信者および受信者が含まれます。
Sender	メッセージをターゲットに送信するためのチャネル。これにはターゲットがあります。
Receiver	ソースからメッセージを受信するためのチャネル。これにはソースがあります。
Source	メッセージの名前付きの発信元。
Target	メッセージの名前付き受信先。
Message	情報のアプリケーション固有の部分。
Delivery	メッセージの転送。

Red Hat build of Rhea は メッセージ を送受信します。メッセージは、sender と receiver を介して、接続されたピアの間で転送されます。送信側および受信側は セッション 上で確立されます。セッションは接続上で確立されます。接続は、一意に識別された 2 つの コンテナー 間で確立されます。コネクションには複数のセッションを含めることができますが、多くの場合は必要ありません。API を使用すると、セッションが必要でない限り、セッションを無視できます。

送信ピアは、メッセージ送信用の送信者を作成します。送信側には、リモートピアでキューまたはトピックを識別する ターゲット があります。受信ピアは、メッセージ受信用の受信者を作成します。受信側には、リモートピアでキューまたはトピックを識別する ソース があります。

メッセージの送信は配信と呼ばれます。メッセージとは、送信される内容のことで、ヘッダーやアノテーションなどのすべてのメタデータが含まれます。配信は、そのコンテンツの移動に関連するプロトコルエクスチェンジです。

配信が完了したことを示すには、送信側または受信側セットのいずれかが解決します。送信側または受信側が解決されたことを知らせると、その配信の通信ができなくなります。受信側は、メッセージを受諾するか、拒否するかどうかを指定することもできます。

1.5. このドキュメントの表記慣例
リンクのコピー

sudo コマンド

このドキュメントでは、root 権限を必要とするすべてのコマンドに対して sudo が使用されています。すべての変更がシステム全体に影響する可能性があるため、sudo を使用する場合は注意が必要です。sudo の詳細は、sudo コマンドの使用を参照してください。

ファイルパス

このドキュメントでは、すべてのファイルパスが Linux、UNIX、および同様のオペレーティングシステムで有効です (例: /home/andrea)。Microsoft Windows では、同等の Windows パスを使用する必要があります (例: C:\Users\andrea)。

変数テキスト

このドキュメントでは、変数を含むコードブロックが紹介されていますが、これは、お客様の環境に固有の値に置き換える必要があります。可変テキストは矢印の中括弧で囲まれ、斜体の等幅フォントとしてスタイル設定されます。たとえば、以下のコマンドでは <project-dir> は実際の環境の値に置き換えます。

cd <project-dir>

$ cd <project-dir>

Copy to Clipboard

Toggle word wrap

第2章インストール
リンクのコピー

この章では、環境に Red Hat build of Rhea をインストールする手順を説明します。

2.1. 前提条件
リンクのコピー

AMQ リリースファイルおよびリポジトリーにアクセスするには、サブスクリプションが必要です。

環境に npm コマンドラインツールをインストールする必要があります。詳細は、npm の Web サイトを参照してください。
Red Hat build of Rhea を使用するには、Node.js を環境にインストールする必要があります。詳細は、Node.js の Web サイトを参照してください。
Red Hat build of Rhea は、Node.js debug モジュールに依存します。インストール手順は、デバッグ npm ページを参照してください。

2.2. Red Hat NPM レジストリーの使用
リンクのコピー

Red Hat NPM レジストリーからクライアントライブラリーをダウンロードするように NPM 環境を設定します。

手順

npm config set コマンドを使用して、Red Hat NPM レジストリーを環境に追加します。
```
sudo npm config set @redhat:registry https://npm.registry.redhat.com
```
```
$ sudo npm config set @redhat:registry https://npm.registry.redhat.com
```
Copy to Clipboard Toggle word wrap
npm install コマンドを使用して、クライアントをインストールします。
```
sudo npm install -g @redhat/rhea@3.0.2-redhat-00001
```
```
$ sudo npm install -g @redhat/rhea@3.0.2-redhat-00001
```
Copy to Clipboard Toggle word wrap

注記

上記の手順は、システム全体のインストール用です。sudo や -g オプションを指定せずにコマンドを実行して、ローカルインストールを実行できます。

インストールされたライブラリーを使用するように環境を設定するには、node_modules/@redhat ディレクトリーを NODE_PATH 環境変数に追加します。

Red Hat Enterprise Linux

export NODE_PATH=/usr/local/lib/node_modules/@redhat:$NODE_PATH

$ export NODE_PATH=/usr/local/lib/node_modules/@redhat:$NODE_PATH

Copy to Clipboard

Toggle word wrap

Windows

set NODE_PATH=%AppData%\Roaming\npm\node_modules\@redhat;%NODE_PATH%

$ set NODE_PATH=%AppData%\Roaming\npm\node_modules\@redhat;%NODE_PATH%

Copy to Clipboard

Toggle word wrap

インストールをテストするには、次のコマンドを使用します。インストールされたライブラリーを正常にインポートすると、コンソールに OK と出力されます。

node -e 'require("rhea")' && echo OK
OK

$ node -e 'require("rhea")' && echo OK
OK

Copy to Clipboard

Toggle word wrap

2.3. ブラウザーへのクライアントのデプロイ
リンクのコピー

Red Hat build of Rhea は、Web ブラウザー内で実行できます。NPM パッケージには、次の場所にある rhea.js という名前のファイルが含まれており、ブラウザーベースのアプリケーションで使用できます。

/usr/local/lib/node_modules/@redhat/rhea/dist/rhea.js

/usr/local/lib/node_modules/@redhat/rhea/dist/rhea.js

Copy to Clipboard

Toggle word wrap

次の例のように、rhea.js ファイルを Web サーバーによって公開されている場所にコピーし、HTML <script> 要素を使用して参照します。

例: ブラウザーでのクライアントの実行

<!DOCTYPE html>
<html>
<head>
  <title>Example</title>
  <script src="rhea.js"></script>
</head>
<body>
  <script>
    const rhea = require("rhea");
    const container = rhea.create_container();

    container.on("message", (event) => {
        console.log(event.message.body);
    });

    const ws = container.websocket_connect(WebSocket);
    const details = ws("ws://example.net:5673", ["binary", "AMQPWSB10", "amqp"])

    const conn = container.connect({"connection_details": details});
    conn.open_receiver("notifications");
  </script>
</body>

<!DOCTYPE html>
<html>
<head>
  <title>Example</title>
  <script src="rhea.js"></script>
</head>
<body>
  <script>
    const rhea = require("rhea");
    const container = rhea.create_container();

    container.on("message", (event) => {
        console.log(event.message.body);
    });

    const ws = container.websocket_connect(WebSocket);
    const details = ws("ws://example.net:5673", ["binary", "AMQPWSB10", "amqp"])

    const conn = container.connect({"connection_details": details});
    conn.open_receiver("notifications");
  </script>
</body>

Copy to Clipboard

Toggle word wrap

2.4. サンプルのインストール
リンクのコピー

git clone コマンドを使用して、ソースリポジトリーを rhea という名前のローカルディレクトリーにクローンします。

git clone https://github.com/amqp/rhea.git

$ git clone https://github.com/amqp/rhea.git

Copy to Clipboard

Toggle word wrap

rhea ディレクトリーに移動し、git checkout コマンドを使用して、このリリースに関連付けられたコミットをチェックアウトします。

cd rhea
git checkout 3.0.2

$ cd rhea
$ git checkout 3.0.2

Copy to Clipboard

Toggle word wrap

このガイドでは、結果のローカルディレクトリーを <source-dir> と呼びます。

第3章スタートガイド
リンクのコピー

この章では、環境を設定して簡単なメッセージングプログラムを実行する手順を説明します。

3.1. 前提条件
リンクのコピー

ご使用の環境のインストール手順を完了している。
インターフェイス localhost およびポート 5672 で接続をリッスンする AMQP 1.0 メッセージブローカーがある。匿名アクセスを有効にする必要があります。詳細は、ブローカーの開始を参照してください。
examples という名前のキューがある。詳細は、キューの作成を参照してください。

3.2. Red Hat Enterprise Linux での Hello World の実行
リンクのコピー

Hello World の例では、ブローカーへの接続を作成し、グリーティングを含むメッセージを examples キューに送信して、受信しなおします。成功すると、受信したメッセージをコンソールに出力します。

examples ディレクトリーに移動し、helloworld.js の例を実行します。

cd <source-dir>/examples
node helloworld.js
Hello World!

$ cd <source-dir>/examples
$ node helloworld.js
Hello World!

Copy to Clipboard

Toggle word wrap

3.3. Microsoft Windows での Hello World の実行
リンクのコピー

examples ディレクトリーに移動し、helloworld.js の例を実行します。

> cd <source-dir>/examples
> node helloworld.js
Hello World!

> cd <source-dir>/examples
> node helloworld.js
Hello World!

Copy to Clipboard

Toggle word wrap

第4章例
リンクのコピー

この章では、サンプルプログラムで Red Hat build of Rhea を使用する方法を説明します。

その他の例は、Rhea サンプルスイートおよび Rhea サンプルを参照してください。

4.1. メッセージの送信
リンクのコピー

このクライアントプログラムは <connection-url> を使用してサーバーに接続し、ターゲット <address> の送信者を作成し、<message-body> を含むメッセージを送信し、接続を切断して終了します。

例: メッセージの送信

"use strict";

var rhea = require("rhea");
var url = require("url");

if (process.argv.length !== 5) {
    console.error("Usage: send.js <connection-url> <address> <message-body>");
    process.exit(1);
}

var conn_url = url.parse(process.argv[2]);
var address = process.argv[3];
var message_body = process.argv[4];

var container = rhea.create_container();

container.on("sender_open", function (event) {
    console.log("SEND: Opened sender for target address '" +
                event.sender.target.address + "'");
});

container.on("sendable", function (event) {
    var message = {
        body: message_body
    };

    event.sender.send(message);

    console.log("SEND: Sent message '" + message.body + "'");

    event.sender.close();
    event.connection.close();
});

var opts = {
    host: conn_url.hostname,
    port: conn_url.port || 5672,
    // To connect with a user and password:
    // username: "<username>",
    // password: "<password>",
};

var conn = container.connect(opts);
conn.open_sender(address);

"use strict";

var rhea = require("rhea");
var url = require("url");

if (process.argv.length !== 5) {
    console.error("Usage: send.js <connection-url> <address> <message-body>");
    process.exit(1);
}

var conn_url = url.parse(process.argv[2]);
var address = process.argv[3];
var message_body = process.argv[4];

var container = rhea.create_container();

container.on("sender_open", function (event) {
    console.log("SEND: Opened sender for target address '" +
                event.sender.target.address + "'");
});

container.on("sendable", function (event) {
    var message = {
        body: message_body
    };

    event.sender.send(message);

    console.log("SEND: Sent message '" + message.body + "'");

    event.sender.close();
    event.connection.close();
});

var opts = {
    host: conn_url.hostname,
    port: conn_url.port || 5672,
    // To connect with a user and password:
    // username: "<username>",
    // password: "<password>",
};

var conn = container.connect(opts);
conn.open_sender(address);

Copy to Clipboard

Toggle word wrap

サンプルの実行

サンプルプログラムを実行するには、サンプルプログラムをローカルファイルにコピーし、node コマンドを使用して呼び出します。詳細は、3章スタートガイド を参照してください。

node send.js amqp://localhost queue1 hello

$ node send.js amqp://localhost queue1 hello

Copy to Clipboard

Toggle word wrap

4.2. メッセージの受信
リンクのコピー

このクライアントプログラムは <connection-url> を使用してサーバーに接続し、ソース <address> の受信側を作成し、終了するか、<count> メッセージに到達するまでメッセージを受信します。

例: メッセージの受信

"use strict";

var rhea = require("rhea");
var url = require("url");

if (process.argv.length !== 4 && process.argv.length !== 5) {
    console.error("Usage: receive.js <connection-url> <address> [<message-count>]");
    process.exit(1);
}

var conn_url = url.parse(process.argv[2]);
var address = process.argv[3];
var desired = 0;
var received = 0;

if (process.argv.length === 5) {
    desired = parseInt(process.argv[4]);
}

var container = rhea.create_container();

container.on("receiver_open", function (event) {
    console.log("RECEIVE: Opened receiver for source address '" +
                event.receiver.source.address + "'");
});

container.on("message", function (event) {
    var message = event.message;

    console.log("RECEIVE: Received message '" + message.body + "'");

    received++;

    if (received == desired) {
        event.receiver.close();
        event.connection.close();
    }
});

var opts = {
    host: conn_url.hostname,
    port: conn_url.port || 5672,
    // To connect with a user and password:
    // username: "<username>",
    // password: "<password>",
};

var conn = container.connect(opts);
conn.open_receiver(address);

"use strict";

var rhea = require("rhea");
var url = require("url");

if (process.argv.length !== 4 && process.argv.length !== 5) {
    console.error("Usage: receive.js <connection-url> <address> [<message-count>]");
    process.exit(1);
}

var conn_url = url.parse(process.argv[2]);
var address = process.argv[3];
var desired = 0;
var received = 0;

if (process.argv.length === 5) {
    desired = parseInt(process.argv[4]);
}

var container = rhea.create_container();

container.on("receiver_open", function (event) {
    console.log("RECEIVE: Opened receiver for source address '" +
                event.receiver.source.address + "'");
});

container.on("message", function (event) {
    var message = event.message;

    console.log("RECEIVE: Received message '" + message.body + "'");

    received++;

    if (received == desired) {
        event.receiver.close();
        event.connection.close();
    }
});

var opts = {
    host: conn_url.hostname,
    port: conn_url.port || 5672,
    // To connect with a user and password:
    // username: "<username>",
    // password: "<password>",
};

var conn = container.connect(opts);
conn.open_receiver(address);

Copy to Clipboard

Toggle word wrap

サンプルの実行

サンプルプログラムを実行するには、サンプルプログラムをローカルファイルにコピーし、python コマンドを使用して呼び出します。詳細は、3章スタートガイド を参照してください。

node receive.js amqp://localhost queue1

$ node receive.js amqp://localhost queue1

Copy to Clipboard

Toggle word wrap

第5章 API の使用
リンクのコピー

詳細は、Rhea API リファレンス、Rhea サンプルスイート、および Rhea サンプルを参照してください。

5.1. メッセージングイベントの処理
リンクのコピー

Red Hat build of Rhea は、非同期イベント駆動型 API です。アプリケーションがイベントを処理する方法を定義するには、ユーザーはイベント処理関数を container オブジェクトに登録します。これらの関数は、ネットワークアクティビティーとして呼び出され、タイマーが新規イベントをトリガーします。

例: メッセージングイベントの処理

var rhea = require("rhea");
var container = rhea.create_container();

container.on("sendable", function (event) {
    console.log("A message can be sent");
});

container.on("message", function (event) {
    console.log("A message is received");
});

var rhea = require("rhea");
var container = rhea.create_container();

container.on("sendable", function (event) {
    console.log("A message can be sent");
});

container.on("message", function (event) {
    console.log("A message is received");
});

Copy to Clipboard

Toggle word wrap

これらはごく一部の一般的なケースイベントのみです。完全なセットは、Rhea API リファレンスに文書化されています。

5.2. イベント関連のオブジェクトへのアクセス
リンクのコピー

event 引数には、イベントが関係するオブジェクトにアクセスするための属性が含まれます。たとえば、connection_open イベントはイベント connection 属性を設定します。

イベントのプライマリーオブジェクトに加えて、イベントのコンテキストを形成する全オブジェクトも設定されます。特定のイベントに対する関連性のない属性は null です。

例: イベント関連のオブジェクトへのアクセス

event.container
event.connection
event.session
event.sender
event.receiver
event.delivery
event.message

event.container
event.connection
event.session
event.sender
event.receiver
event.delivery
event.message

Copy to Clipboard

Toggle word wrap

5.3. コンテナーの作成
リンクのコピー

コンテナーは最上位の API オブジェクトです。これは、接続を作成するエントリーポイントであり、メインのイベントループを実行します。多くの場合、これはグローバルイベントハンドラーで構築されます。

例: コンテナーの作成

var rhea = require("rhea");
var container = rhea.create_container();

var rhea = require("rhea");
var container = rhea.create_container();

Copy to Clipboard

Toggle word wrap

5.4. コンテナーアイデンティティーの設定
リンクのコピー

各コンテナーインスタンスには、コンテナー ID と呼ばれる一意のアイデンティティーがあります。Red Hat build of Rhea がネットワーク接続を作成すると、コンテナー ID がリモートピアに送信されます。コンテナー ID を設定するには、id オプションを create_container メソッドに渡します。

例: コンテナーアイデンティティーの設定

var container = rhea.create_container({id: "job-processor-3"});

var container = rhea.create_container({id: "job-processor-3"});

Copy to Clipboard

Toggle word wrap

ユーザーが ID を設定しないと、コンテナーの構築時にライブラリーが UUID を生成します。

第6章ネットワーク接続
リンクのコピー

6.1. 外向き接続の作成
リンクのコピー

リモートサーバーに接続するには、ホストとポートを含む接続オプションを container.connect() メソッドに渡します。

例: 外向き接続の作成

container.on("connection_open", function (event) {
    console.log("Connection " + event.connection + " is open");
});

var opts = {
    host: "example.com",
    port: 5672
};

container.connect(opts);

container.on("connection_open", function (event) {
    console.log("Connection " + event.connection + " is open");
});

var opts = {
    host: "example.com",
    port: 5672
};

container.connect(opts);

Copy to Clipboard

Toggle word wrap

デフォルトのホストは localhost です。デフォルトのポートは 5672 です。

セキュアな接続の作成に関する詳細は、7章セキュリティー を参照してください。

6.2. 再接続の設定
リンクのコピー

再接続することで、クライアントは失われた接続から復旧できます。これは、一時的なネットワークまたはコンポーネントの障害後に、分散システムのコンポーネントが再確立されるように使用されます。

Red Hat build of Rhea は、デフォルトで再接続を有効にします。接続試行に失敗すると、クライアントは少しの遅延の後に再度試行します。遅延は、デフォルトの最大値 60 秒まで、新しい試行ごとに指数関数的に増加します。

再接続を無効にするには、reconnect 接続オプションを false に設定します。

例: 再接続の無効化

var opts = {
    host: "example.com",
    reconnect: false
};

container.connect(opts);

var opts = {
    host: "example.com",
    reconnect: false
};

container.connect(opts);

Copy to Clipboard

Toggle word wrap

次の接続試行までの間の遅延を制御するには、接続オプション initial_reconnect_delay および max_reconnect_delay を設定します。遅延オプションはミリ秒単位で指定します。

再接続試行回数を制限するには、reconnect_limit オプションを設定します。

例: 再接続の設定例

var opts = {
    host: "example.com",
    initial_reconnect_delay: 100,
    max_reconnect_delay: 60 * 1000,
    reconnect_limit: 10
};

container.connect(opts);

var opts = {
    host: "example.com",
    initial_reconnect_delay: 100,
    max_reconnect_delay: 60 * 1000,
    reconnect_limit: 10
};

container.connect(opts);

Copy to Clipboard

Toggle word wrap

6.3. フェイルオーバーの設定
リンクのコピー

Red Hat build of Rhea を使用すると、代わりの接続エンドポイントをプログラムで設定できます。

複数の接続エンドポイントを指定するには、新しい接続オプションを返す関数を定義し、connection_details オプションで関数を渡します。この関数は、接続試行ごとに 1 回呼び出されます。

例: フェイルオーバーの設定

var hosts = [{hostname: "alpha.example.com", port: 5672}, {hostname:"beta.example.com", port: 5672}];
var index = -1;

function failover_fn() {
    index += 1;

    if (index == hosts.length) index = 0;

    return {host: hosts[index].hostname, port: hosts[index].port};
};

var opts = {
    host: "example.com",
    connection_details: failover_fn
}

container.connect(opts);

var hosts = [{hostname: "alpha.example.com", port: 5672}, {hostname:"beta.example.com", port: 5672}];
var index = -1;

function failover_fn() {
    index += 1;

    if (index == hosts.length) index = 0;

    return {host: hosts[index].hostname, port: hosts[index].port};
};

var opts = {
    host: "example.com",
    connection_details: failover_fn
}

container.connect(opts);

Copy to Clipboard

Toggle word wrap

この例では、ホストのリストに対してラウンドロビンフェイルオーバーを繰り返すように実装します。このインターフェイスを使用して、独自のフェイルオーバー動作を実装できます。

6.4. 内向き接続の許可
リンクのコピー

Red Hat build of Rhea はインバウンドネットワーク接続を受け入れ、カスタムメッセージングサーバーを構築できます。

接続のリッスンを開始するには、container.listen() メソッドを使用して、ローカルホストアドレスとリッスンするポートが含まれるオプションを指定します。

例: 内向き接続の許可

container.on("connection_open", function (event) {
    console.log("New incoming connection " + event.connection);
});

var opts = {
    host: "0.0.0.0",
    port: 5672
};

container.listen(opts);

container.on("connection_open", function (event) {
    console.log("New incoming connection " + event.connection);
});

var opts = {
    host: "0.0.0.0",
    port: 5672
};

container.listen(opts);

Copy to Clipboard

Toggle word wrap

特別な IP アドレス 0.0.0.0 は、利用可能なすべての IPv4 インターフェイスでリッスンします。すべての IPv6 インターフェイスをリッスンするには [::0] を使用します。

詳細は、サーバー receive.js の例を参照してください。

第7章セキュリティー
リンクのコピー

7.1. SSL/TLS を使用した接続のセキュリティー保護
リンクのコピー

Red Hat build of Rhea は SSL/TLS を使用して、クライアントとサーバー間の通信を暗号化します。

SSL/TLS を使用してリモートサーバーに接続するには、transport 接続オプションを tls に設定します。

例: SSL/TLS の有効化

var opts = {
    host: "example.com",
    port: 5671,
    transport: "tls"
};

container.connect(opts);

var opts = {
    host: "example.com",
    port: 5671,
    transport: "tls"
};

container.connect(opts);

Copy to Clipboard

Toggle word wrap

注記

デフォルトでは、クライアントは信頼できない証明書が割り当てられたサーバーへの接続を拒否します。これは、テスト環境などが該当します。証明書の認証を省略するには、rejectUnauthorized 接続オプションを false に設定します。これにより、接続のセキュリティーが危険にさらされることに注意してください。

7.2. ユーザーとパスワードを使用した接続
リンクのコピー

Red Hat build of Rhea は、ユーザーとパスワードによる接続を認証できます。

認証に使用する認証情報を指定するには、接続オプション username と password を設定します。

例: ユーザーとパスワードを使用した接続

var opts = {
    host: "example.com",
    username: "alice",
    password: "secret"
};

container.connect(opts);

var opts = {
    host: "example.com",
    username: "alice",
    password: "secret"
};

container.connect(opts);

Copy to Clipboard

Toggle word wrap

7.3. SASL 認証の設定
リンクのコピー

Red Hat build of Rhea は SASL プロトコルを使用して認証を実行します。SASL はさまざまな認証 メカニズム を使用できます。ネットワークピアが 2 つ接続すると、許可されたメカニズムが交換され、両方で許可されている最も強力なメカニズムが選択されます。

Red Hat build of Rhea は、ユーザーとパスワード情報があるかどうかによって SASL メカニズムを有効にします。ユーザーとパスワードの両方が指定されている場合は、PLAIN が使用されます。ユーザーのみを指定すると、ANONYMOUS が使用されます。いずれも指定されていない場合、SASL は無効になります。

第8章送信者と受信者
リンクのコピー

クライアントは、送信者と受信者のリンクを使用して、メッセージ配信のチャネルを表現します。送信者と受信者は一方向であり、送信元はメッセージの発信元に、ターゲットはメッセージの宛先になります。

ソースとターゲットは、多くの場合、メッセージブローカーのキューまたはトピックを参照します。ソースは、サブスクリプションを表すためにも使用されます。

8.1. オンデマンドでのキューとトピックの作成
リンクのコピー

メッセージサーバーによっては、キューとトピックのオンデマンド作成をサポートします。送信側または受信側が割り当てられている場合、サーバーは送信側ターゲットアドレスまたは受信側ソースアドレスを使用して、アドレスに一致する名前でキューまたはトピックを作成します。

メッセージサーバーは通常、キュー (1 対 1 のメッセージ配信用) またはトピック (1 対多のメッセージ配信用) を作成します。クライアントは、ソースまたはターゲットに queue または topic 機能を設定してどちらを優先するかを示すことができます。

キューまたはトピックセマンティクスを選択するには、以下の手順に従います。

キューとトピックを自動的に作成するようにメッセージサーバーを設定します。多くの場合は、これがデフォルト設定になります。
以下の例のように、送信者ターゲットまたは受信者ソースに queue または topic 機能を設定します。

例: オンデマンドで作成されたキューへの送信

var conn = container.connect({host: "example.com"});

var sender_opts = {
    target: {
        address: "jobs",
        capabilities: ["queue"]
    }
}

conn.open_sender(sender_opts);

var conn = container.connect({host: "example.com"});

var sender_opts = {
    target: {
        address: "jobs",
        capabilities: ["queue"]
    }
}

conn.open_sender(sender_opts);

Copy to Clipboard

Toggle word wrap

例: オンデマンドで作成されたトピックからの受信

var conn = container.connect({host: "example.com"});

var receiver_opts = {
    source: {
        address: "notifications",
        capabilities: ["topic"]
    }
}

conn.open_receiver(receiver_opts);

var conn = container.connect({host: "example.com"});

var receiver_opts = {
    source: {
        address: "notifications",
        capabilities: ["topic"]
    }
}

conn.open_receiver(receiver_opts);

Copy to Clipboard

Toggle word wrap

詳細は、以下の例を参照してください。

8.2. 永続サブスクリプションの作成
リンクのコピー

永続サブスクリプションは、メッセージの受信側を表すリモートサーバーの状態です。通常、メッセージ受信者は、クライアントが終了すると、破棄されます。ただし、永続サブスクリプションは永続的であるため、クライアントはそれらのサブスクリプションの割り当てを解除してから、後で再度アタッチできます。デタッチ時に受信したすべてのメッセージは、クライアントの再割り当て時に利用できます。

永続サブスクリプションは、クライアントコンテナー ID とレシーバー名を組み合わせてサブスクリプション ID を形成することで一意に識別されます。これらには、サブスクリプションを回復できるように、安定した値が必要です。

接続コンテナー ID を client-1 などの安定した値に設定します。
```
var container = rhea.create_container({id: "client-1"});
```
```
var container = rhea.create_container({id: "client-1"});
```
Copy to Clipboard Toggle word wrap

sub-1 などの安定した名前で受信側を作成し、durable および expiry_policy プロパティーを指定して、受信者のソースが永続化されるように設定します。

var receiver_opts = {
    source: {
        address: "notifications",
        name: "sub-1",
        durable: 2,
        expiry_policy: "never"
    }
}

conn.open_receiver(receiver_opts);

var receiver_opts = {
    source: {
        address: "notifications",
        name: "sub-1",
        durable: 2,
        expiry_policy: "never"
    }
}

conn.open_receiver(receiver_opts);

Copy to Clipboard

Toggle word wrap

サブスクリプションからデタッチするには、receiver.detach() メソッドを使用します。サブスクリプションを終了するには、receiver.close() メソッドを使用します。

詳細は、durable-subscribe.js の例を参照してください。

8.3. 共有サブスクリプションの作成
リンクのコピー

共有サブスクリプションとは、1 つ以上のメッセージレシーバーを表すリモートサーバーの状態のことです。このサブスクリプションは共有されているため、複数のクライアントが同じメッセージのストリームから消費できます。

クライアントは、受信者のソースに shared 機能を設定して、共有サブスクリプションを設定します。

共有サブスクリプションは、クライアントコンテナー ID とレシーバー名を組み合わせてサブスクリプション ID を形成することで一意に識別されます。複数のクライアントプロセスで同じサブスクリプションを特定できるように、これらに安定した値を指定する必要があります。shared に加えて global 機能が設定されている場合は、サブスクリプションの識別に受信者名だけが使用されます。

永続サブスクリプションを作成するには、以下の手順に従います。

接続コンテナー ID を client-1 などの安定した値に設定します。
```
var container = rhea.create_container({id: "client-1"});
```
```
var container = rhea.create_container({id: "client-1"});
```
Copy to Clipboard Toggle word wrap

sub-1 などの安定した名前で受信者を作成し、shared 機能を設定して共有用に受信者のソースを設定します。

var receiver_opts = {
    source: {
        address: "notifications",
        name: "sub-1",
        capabilities: ["shared"]
    }
}

conn.open_receiver(receiver_opts);

var receiver_opts = {
    source: {
        address: "notifications",
        name: "sub-1",
        capabilities: ["shared"]
    }
}

conn.open_receiver(receiver_opts);

Copy to Clipboard

Toggle word wrap

詳細は、shared-subscribe.js の例を参照してください。

第9章エラー処理
リンクのコピー

Red Hat build of Rhea のエラーは、AMQP プロトコルまたは接続エラーに対応する名前付きイベントをインターセプトすることで処理できます。

9.1. 接続およびプロトコルエラーの処理
リンクのコピー

以下のイベントをインターセプトして、プロトコルレベルのエラーを処理できます。

connection_error
session_error
sender_error
receiver_error
protocol_error
error

これらのイベントは、イベントにある特定のオブジェクトにエラー状態が生じるたびに実行されます。エラーハンドラーを呼び出すと、対応する <object>_close ハンドラーも呼び出されます。

event 引数には、エラーオブジェクトにアクセスするための error 属性があります。

例: エラーの処理

container.on("error", function (event) {
    console.log("An error!", event.error);
});

container.on("error", function (event) {
    console.log("An error!", event.error);
});

Copy to Clipboard

Toggle word wrap

注記

クローズハンドラーはエラー発生時に呼び出されるため、エラーハンドラー内でのみ処理する必要があります。リソースのクリーンアップは、近辺にあるハンドラーで管理できます。特定のオブジェクトに固有のエラー処理がない場合は、一般的な error イベントを処理してより具体的なハンドラーを持たないのが一般的です。

注記

再接続が有効になっており、リモートサーバーが amqp:connection:forced の条件で接続が切断されると、クライアントはこれをエラーとして処理しないため、connection_error イベントは実行されません。代わりに、クライアントが再接続プロセスを開始します。

第10章ロギング
リンクのコピー

10.1. ロギングの設定
リンクのコピー

Red Hat build of Rhea は JavaScript デバッグモジュールを使用してロギングを実装します。

たとえば、詳細なクライアントロギングを有効にするには、DEBUG 環境変数を rhea* に設定します。

例: 詳細ログの有効化

export DEBUG=rhea*
<your-client-program>

$ export DEBUG=rhea*
$ <your-client-program>

Copy to Clipboard

Toggle word wrap

10.2. プロトコルロギングの有効化
リンクのコピー

クライアントは AMQP プロトコルフレームをコンソールに記録できます。多くの場合、このデータは問題の診断時に重要になります。

プロトコルロギングを有効にするには、DEBUG 環境変数を rhea:frames に設定します。

例: プロトコルロギングの有効化

export DEBUG=rhea:frames
<your-client-program>

$ export DEBUG=rhea:frames
$ <your-client-program>

Copy to Clipboard

Toggle word wrap

第11章ファイルベースの設定
リンクのコピー

Red Hat build of Rhea は、connect.json という名前のローカルファイルからの接続確立に使用される設定オプションを読み取ることができます。これにより、デプロイメント時にアプリケーションで接続を設定できます。

ライブラリーは、接続オプションを指定せずにアプリケーションがコンテナーの connect メソッドを呼び出すと、ファイルの読み取りを試みます。

11.1. ファイルの場所
リンクのコピー

設定されていると、Red Hat build of Rhea は MESSAGING_CONNECT_FILE 環境変数の値を使用して設定ファイルを検索します。

MESSAGING_CONNECT_FILE が設定されていないと、Red Hat build of Rhea は以下の場所で connect.json という名前のファイルを検索します。最初の一致で停止します。

Linux の場合:

$PWD/connect.json: $PWD は、クライアントプロセスの現在の作業ディレクトリーです。
$HOME/.config/messaging/connect.json: $HOME は、現在のユーザーのホームディレクトリーに置き換えます。
/etc/messaging/connect.json

Windows の場合:

%cd%/connect.json: %cd% は、クライアントプロセスの現在の作業ディレクトリーです。

connect.json ファイルが見つからない場合、ライブラリーはすべてのオプションにデフォルト値を使用します。

11.2. ファイル形式
リンクのコピー

connect.json ファイルには JSON データが含まれており、JavaScript コメントもサポートされています。

設定属性はすべてオプションであるか、デフォルト値が設定されているため、簡単な例では詳細をいくつか指定するだけで済みます。

例: 簡単な connect.json ファイル

{
    "host": "example.com",
    "user": "alice",
    "password": "secret"
}

{
    "host": "example.com",
    "user": "alice",
    "password": "secret"
}

Copy to Clipboard

Toggle word wrap

SASL および SSL/TLS オプションは、"sasl" および "tls" namespace で入れ子になっています。

例: SASL および SSL/TLS オプションを含む connect.json ファイル

{
    "host": "example.com",
    "user": "ortega",
    "password": "secret",
    "sasl": {
        "mechanisms": ["SCRAM-SHA-1", "SCRAM-SHA-256"]
    },
    "tls": {
        "cert": "/home/ortega/cert.pem",
        "key": "/home/ortega/key.pem"
    }
}

{
    "host": "example.com",
    "user": "ortega",
    "password": "secret",
    "sasl": {
        "mechanisms": ["SCRAM-SHA-1", "SCRAM-SHA-256"]
    },
    "tls": {
        "cert": "/home/ortega/cert.pem",
        "key": "/home/ortega/key.pem"
    }
}

Copy to Clipboard

Toggle word wrap

11.3. 設定オプション
リンクのコピー

ドット (.) を含むオプションキーは、namespace にネストされた属性を表します。

Expand

表11.1 connect.json の設定オプション
キー	値の型	デフォルト値	説明
`scheme`	string	`"amqps"`	SSL/TLS のクリアテキストまたは `"amqps"` の場合は `"amqp"`
`host`	string	`"localhost"`	リモートホストのホスト名または IP アドレス
`port`	string または number	`"amqps"`	ポート番号またはポートリテラル
`user`	string	なし	認証のユーザー名
`password`	string	なし	認証のパスワード
`sasl.mechanisms`	list または string	なし (システムのデフォルト)	有効な SASL メカニズムの JSON リスト。ベア文字列は 1 つのメカニズムを表します。指定がない場合、クライアントはシステムによって提供されるデフォルトのメカニズムを使用します。
`sasl.allow_insecure`	boolean	`false`	クリアテキストパスワードを送信するメカニズムの有効化
`tls.cert`	string	なし	クライアント証明書のファイル名またはデータベース ID
`tls.key`	string	なし	クライアント証明書の秘密鍵のファイル名またはデータベース ID
`tls.ca`	string	なし	CA 証明書のファイル名、ディレクトリー、またはデータベース ID
`tls.verify`	boolean	`true`	ホスト名が一致する、有効なサーバー証明書が必要

第12章相互運用性
リンクのコピー

この章では、Red Hat build of Rhea を他の AMQ コンポーネントと組み合わせて使用する方法を説明します。AMQ コンポーネントの互換性の概要は、製品の概要を参照してください。

12.1. 他の AMQP クライアントとの相互運用
リンクのコピー

AMQP メッセージは AMQP 型のシステムを使用して構成されます。このような一般的な形式は、異なる言語の AMQP クライアントが相互に対話できる理由の 1 つです。

メッセージを送信する場合、Red Hat build of Rhea は自動的に言語ネイティブの型を AMQP でエンコードされたデータに変換します。メッセージの受信時に、リバース変換が行われます。

注記

AMQP の型の詳細は、Apache Qpid プロジェクトによって維持されるインタラクティブ型リファレンスを参照してください。

Expand

表12.1 AMQP 型
AMQP 型	説明
`null`	空の値
`boolean`	true または false の値
`char`	単一の Unicode 文字
`string`	Unicode 文字のシーケンス
`binary`	バイトのシーケンス
`byte`	署名済み 8 ビット整数
`short`	署名済み 16 ビット整数
`int`	署名済み 32 ビット整数
`long`	署名済み 64 ビット整数
`ubyte`	署名なしの 8 ビット整数
`ushort`	署名なしの 16 ビット整数
`uint`	署名なしの 32 ビット整数
`ulong`	署名なしの 64 ビット整数
`float`	32 ビット浮動小数点数
`double`	64 ビット浮動小数点数
`array`	単一型の値シーケンス
`list`	変数型の値シーケンス
`map`	異なるキーから値へのマッピング
`uuid`	ユニバーサル一意識別子
`symbol`	制限されたドメインからの 7 ビットの ASCII 文字列
`timestamp`	絶対的な時間

JavaScript にあるネイティブ型は、AMQP がエンコードできる数よりも少なくなっています。特定の AMQP 型を含むメッセージを送信するには、rhea/types.js モジュールの wrap_ 関数を使用します。

Expand

表12.2 エンコード前およびデコード後における Rhea の型
AMQP 型	エンコード前の Rhea の型	デコード後の Rhea の型
`null`	`null`	`null`
`boolean`	`boolean`	`boolean`
`char`	`wrap_char(number)`	`number`
`string`	`string`	`string`
`binary`	`wrap_binary(string)`	`string`
`byte`	`wrap_byte(number)`	`number`
`short`	`wrap_short(number)`	`number`
`int`	`wrap_int(number)`	`number`
`long`	`wrap_long(number)`	`number`
`ubyte`	`wrap_ubyte(number)`	`number`
`ushort`	`wrap_ushort(number)`	`number`
`uint`	`wrap_uint(number)`	`number`
`ulong`	`wrap_ulong(number)`	`number`
`float`	`wrap_float(number)`	`number`
`double`	`wrap_double(number)`	`number`
`array`	`wrap_array(Array, code)`	`Array`
`list`	`wrap_list(Array)`	`Array`
`map`	`wrap_map(object)`	`object`
`uuid`	`wrap_uuid(number)`	`number`
`symbol`	`wrap_symbol(string)`	`string`
`timestamp`	`wrap_timestamp(number)`	`number`

Expand

表12.3 Rhea およびその他の AMQ クライアントの型 (1/2)
エンコード前の Rhea の型	AMQ C++ 型	Red Hat build of Apache Qpid Proton DotNet 型
`null`	`nullptr`	`null`
`boolean`	`bool`	`System.Boolean`
`wrap_char(number)`	`wchar_t`	`System.Char`
`string`	`std::string`	`system.String`
`wrap_binary(string)`	`proton::binary`	`System.Byte[]`
`wrap_byte(number)`	`int8_t`	`system.SByte`
`wrap_short(number)`	`int16_t`	`System.Int16`
`wrap_int(number)`	`int32_t`	`System.Int32`
`wrap_long(number)`	`int64_t`	`System.Int64`
`wrap_ubyte(number)`	`uint8_t`	`System.Byte`
`wrap_ushort(number)`	`uint16_t`	`System.UInt16`
`wrap_uint(number)`	`uint32_t`	`System.UInt32`
`wrap_ulong(number)`	`uint64_t`	`System.UInt64`
`wrap_float(number)`	`float`	`System.Single`
`wrap_double(number)`	`double`	`system.Double`
`wrap_array(Array, code)`	-	-
`wrap_list(Array)`	`std::vector`	`Amqp.List`
`wrap_map(object)`	`std::map`	`Amqp.Map`
`wrap_uuid(number)`	`proton::uuid`	`System.Guid`
`wrap_symbol(string)`	`proton::symbol`	`Amqp.Symbol`
`wrap_timestamp(number)`	`proton::timestamp`	`System.DateTime`

Expand

表12.4 Rhea およびその他の AMQ クライアントの型 (2/2)
エンコード前の Rhea の型	Red Hat build of Apache Qpid Proton Python の型
`null`	`なし`
`boolean`	`bool`
`string`	`unicode`
`wrap_char(number)`	`unicode`
`wrap_binary(string)`	`bytes`
`wrap_byte(number)`	`int`
`wrap_short(number)`	`int`
`wrap_int(number)`	`long`
`wrap_long(number)`	`long`
`wrap_ubyte(number)`	`long`
`wrap_ushort(number)`	`long`
`wrap_uint(number)`	`long`
`wrap_ulong(number)`	`long`
`wrap_float(number)`	`float`
`wrap_double(number)`	`float`
`wrap_array(Array, code)`	`proton.Array`
`wrap_list(Array)`	`list`
`wrap_map(object)`	`dict`
`wrap_uuid(number)`	-
`wrap_symbol(string)`	`str`
`wrap_timestamp(number)`	`long`

12.2. Red Hat build of Apache Qpid JMS との相互運用
リンクのコピー

AMQP は JMS メッセージングモデルへの標準マッピングを定義します。このセクションでは、そのマッピングのさまざまな側面を説明します。詳細は、Red Hat build of Apache Qpid JMS 相互運用性の章を参照してください。

JMS メッセージ型

Red Hat build of Rhea は、本文の型が異なる、単一のメッセージを提供します。一方、JMS API は異なるメッセージの型を使用してさまざまな種類のデータを表します。次の表は、特定の body の型が JMS メッセージの型にどのようにマップされるかを示しています。

作成される JMS メッセージの型をさらに明示的に制御するには、x-opt-jms-msg-type メッセージアノテーションを設定できます。詳細は、Red Hat build of Apache Qpid JMS 相互運用性の章を参照してください。

Expand

表12.5 Rhea および JMS メッセージの型
Rhea ボディーの型	JMS メッセージの型
`string`	`TextMessage`
`null`	`TextMessage`
`wrap_binary(string)`	`BytesMessage`
それ以外の型	`ObjectMessage`

12.3. AMQ Broker への接続
リンクのコピー

AMQ Broker は AMQP 1.0 クライアントと相互運用するために設計されています。以下を確認して、ブローカーが AMQP メッセージング用に設定されていることを確認します。

ネットワークファイアウォールのポート 5672 が開いている。
AMQ Broker AMQP アクセプターが有効になっている。デフォルトのアクセプター設定を参照してください。
必要なアドレスがブローカーに設定されている。アドレス、キュー、およびトピックを参照してください。
ブローカーはクライアントからのアクセスを許可するように設定され、クライアントは必要な認証情報を送信するように設定されている。Broker Security を参照してください。

付録A サブスクリプションの使用
リンクのコピー

AMQ は、ソフトウェアサブスクリプションから提供されます。サブスクリプションを管理するには、Red Hat カスタマーポータルでアカウントにアクセスします。

A.1. アカウントへのアクセス
リンクのコピー

手順

access.redhat.com に移動します。
アカウントがない場合は作成します。
アカウントにログインします。

A.2. サブスクリプションのアクティベート
リンクのコピー

手順

access.redhat.com に移動します。
My Subscriptions に移動します。
Activate a subscription に移動し、16 桁のアクティベーション番号を入力します。

A.3. リリースファイルのダウンロード
リンクのコピー

.zip、.tar.gz、およびその他のリリースファイルにアクセスするには、カスタマーポータルを使用してダウンロードする関連ファイルを検索します。RPM パッケージまたは Red Hat Maven リポジトリーを使用している場合、この手順は必要ありません。

手順

ブラウザーを開き、access.redhat.com/downloads で Red Hat カスタマーポータルの Product Downloads ページにログインします。
INTEGRATION AND AUTOMATION カテゴリーの Red Hat AMQ エントリーを見つけます。
必要な AMQ 製品を選択します。Software Downloads ページが開きます。
コンポーネントの Download リンクをクリックします。

A.4. パッケージ用システムの登録
リンクのコピー

この製品の RPM パッケージを Red Hat Enterprise Linux にインストールするには、システムが登録されている必要があります。ダウンロードしたリリースファイルを使用している場合、この手順は必要ありません。

手順

access.redhat.com に移動します。
Registration Assistant に移動します。
ご使用の OS バージョンを選択し、次のページに進みます。
システムの端末にリスト表示されたコマンドを使用して、登録を完了します。

システムを登録する方法は、以下のリソースを参照してください。

付録B 例で AMQ ブローカーの使用
リンクのコピー

Red Hat build of Rhea の例では、名前が examples というキューが含まれる実行中のメッセージブローカーが必要です。以下の手順に従って、ブローカーをインストールして起動し、キューを定義します。

B.1. ブローカーのインストール
リンクのコピー

Getting Started with AMQ Broker の手順に従って、ブローカーをインストールして、ブローカーインスタンスを作成します。匿名アクセスを有効にします。

以下の手順では、ブローカーインスタンスの場所を <broker-instance-dir> と呼びます。

B.2. ブローカーの起動
リンクのコピー

手順

artemis run コマンドを使用してブローカーを起動します。
```
<broker-instance-dir>/bin/artemis run
```
```
$ <broker-instance-dir>/bin/artemis run
```
Copy to Clipboard Toggle word wrap

起動時にログに記録された重大なエラーがないか、コンソールの出力を確認してください。ブローカーでは、準備が整うと Server is now live とログに記録されます。

example-broker/bin/artemis run
           __  __  ____    ____            _
     /\   |  \/  |/ __ \  |  _ \          | |
    /  \  | \  / | |  | | | |_) |_ __ ___ | | _____ _ __
   / /\ \ | |\/| | |  | | |  _ <| '__/ _ \| |/ / _ \ '__|
  / ____ \| |  | | |__| | | |_) | | | (_) |   <  __/ |
 /_/    \_\_|  |_|\___\_\ |____/|_|  \___/|_|\_\___|_|

 Red Hat AMQ <version>

2020-06-03 12:12:11,807 INFO  [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server
...
2020-06-03 12:12:12,336 INFO  [org.apache.activemq.artemis.core.server] AMQ221007: Server is now live
...

$ example-broker/bin/artemis run
           __  __  ____    ____            _
     /\   |  \/  |/ __ \  |  _ \          | |
    /  \  | \  / | |  | | | |_) |_ __ ___ | | _____ _ __
   / /\ \ | |\/| | |  | | |  _ <| '__/ _ \| |/ / _ \ '__|
  / ____ \| |  | | |__| | | |_) | | | (_) |   <  __/ |
 /_/    \_\_|  |_|\___\_\ |____/|_|  \___/|_|\_\___|_|

 Red Hat AMQ <version>

2020-06-03 12:12:11,807 INFO  [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server
...
2020-06-03 12:12:12,336 INFO  [org.apache.activemq.artemis.core.server] AMQ221007: Server is now live
...

Copy to Clipboard

Toggle word wrap

B.3. キューの作成
リンクのコピー

新しいターミナルで、artemis queue コマンドを使用して examples という名前のキューを作成します。

<broker-instance-dir>/bin/artemis queue create --name examples --address examples --auto-create-address --anycast

$ <broker-instance-dir>/bin/artemis queue create --name examples --address examples --auto-create-address --anycast

Copy to Clipboard

Toggle word wrap

プロンプトで質問に Yes または No で回答するように求められます。すべての質問に N (いいえ) と回答します。

キューが作成されると、ブローカーはサンプルプログラムで使用できるようになります。

B.4. ブローカーの停止
リンクのコピー

サンプルの実行が終了したら、artemis stop コマンドを使用してブローカーを停止します。

<broker-instance-dir>/bin/artemis stop

$ <broker-instance-dir>/bin/artemis stop

Copy to Clipboard

Toggle word wrap

改訂日時: 2024-02-10

法律上の通知
リンクのコピー

The text of and illustrations in this document are licensed by Red Hat under a Creative Commons Attribution–Share Alike 3.0 Unported license ("CC-BY-SA"). An explanation of CC-BY-SA is available at http://creativecommons.org/licenses/by-sa/3.0/. In accordance with CC-BY-SA, if you distribute this document or an adaptation of it, you must provide the URL for the original version.

Red Hat, as the licensor of this document, waives the right to enforce, and agrees not to assert, Section 4d of CC-BY-SA to the fullest extent permitted by applicable law.

Red Hat, Red Hat Enterprise Linux, the Shadowman logo, the Red Hat logo, JBoss, OpenShift, Fedora, the Infinity logo, and RHCE are trademarks of Red Hat, Inc., registered in the United States and other countries.

Linux® is the registered trademark of Linus Torvalds in the United States and other countries.

Java® is a registered trademark of Oracle and/or its affiliates.

XFS® is a trademark of Silicon Graphics International Corp. or its subsidiaries in the United States and/or other countries.

MySQL® is a registered trademark of MySQL AB in the United States, the European Union and other countries.

Node.js® is an official trademark of Joyent. Red Hat is not formally related to or endorsed by the official Joyent Node.js open source or commercial project.

The OpenStack® Word Mark and OpenStack logo are either registered trademarks/service marks or trademarks/service marks of the OpenStack Foundation, in the United States and other countries and are used with the OpenStack Foundation's permission. We are not affiliated with, endorsed or sponsored by the OpenStack Foundation, or the OpenStack community.

All other trademarks are the property of their respective owners.

Rhea の使用

JavaScript を使用した AMQ メッセージングクライアントの開発

多様性を受け入れるオープンソースの強化リンクのコピーリンクがクリップボードにコピーされました!

第1章 概要リンクのコピーリンクがクリップボードにコピーされました!

1.1. 主な特長リンクのコピーリンクがクリップボードにコピーされました!

1.2. サポートされる標準およびプロトコルリンクのコピーリンクがクリップボードにコピーされました!

1.3. サポートされる構成リンクのコピーリンクがクリップボードにコピーされました!

1.4. 用語および概念リンクのコピーリンクがクリップボードにコピーされました!

1.5. このドキュメントの表記慣例リンクのコピーリンクがクリップボードにコピーされました!

sudo コマンド

ファイルパス

変数テキスト

第2章 インストールリンクのコピーリンクがクリップボードにコピーされました!

2.1. 前提条件リンクのコピーリンクがクリップボードにコピーされました!

2.2. Red Hat NPM レジストリーの使用リンクのコピーリンクがクリップボードにコピーされました!

2.3. ブラウザーへのクライアントのデプロイリンクのコピーリンクがクリップボードにコピーされました!

2.4. サンプルのインストールリンクのコピーリンクがクリップボードにコピーされました!

第3章 スタートガイドリンクのコピーリンクがクリップボードにコピーされました!

3.1. 前提条件リンクのコピーリンクがクリップボードにコピーされました!

3.2. Red Hat Enterprise Linux での Hello World の実行リンクのコピーリンクがクリップボードにコピーされました!

3.3. Microsoft Windows での Hello World の実行リンクのコピーリンクがクリップボードにコピーされました!

第4章 例リンクのコピーリンクがクリップボードにコピーされました!

4.1. メッセージの送信リンクのコピーリンクがクリップボードにコピーされました!

サンプルの実行

4.2. メッセージの受信リンクのコピーリンクがクリップボードにコピーされました!

サンプルの実行

第5章 API の使用リンクのコピーリンクがクリップボードにコピーされました!

5.1. メッセージングイベントの処理リンクのコピーリンクがクリップボードにコピーされました!

5.2. イベント関連のオブジェクトへのアクセスリンクのコピーリンクがクリップボードにコピーされました!

5.3. コンテナーの作成リンクのコピーリンクがクリップボードにコピーされました!

5.4. コンテナーアイデンティティーの設定リンクのコピーリンクがクリップボードにコピーされました!

第6章 ネットワーク接続リンクのコピーリンクがクリップボードにコピーされました!

6.1. 外向き接続の作成リンクのコピーリンクがクリップボードにコピーされました!

6.2. 再接続の設定リンクのコピーリンクがクリップボードにコピーされました!

6.3. フェイルオーバーの設定リンクのコピーリンクがクリップボードにコピーされました!

6.4. 内向き接続の許可リンクのコピーリンクがクリップボードにコピーされました!

第7章 セキュリティーリンクのコピーリンクがクリップボードにコピーされました!

7.1. SSL/TLS を使用した接続のセキュリティー保護リンクのコピーリンクがクリップボードにコピーされました!

7.2. ユーザーとパスワードを使用した接続リンクのコピーリンクがクリップボードにコピーされました!

7.3. SASL 認証の設定リンクのコピーリンクがクリップボードにコピーされました!

第8章 送信者と受信者リンクのコピーリンクがクリップボードにコピーされました!

8.1. オンデマンドでのキューとトピックの作成リンクのコピーリンクがクリップボードにコピーされました!

8.2. 永続サブスクリプションの作成リンクのコピーリンクがクリップボードにコピーされました!

8.3. 共有サブスクリプションの作成リンクのコピーリンクがクリップボードにコピーされました!

第9章 エラー処理リンクのコピーリンクがクリップボードにコピーされました!

9.1. 接続およびプロトコルエラーの処理リンクのコピーリンクがクリップボードにコピーされました!

第10章 ロギングリンクのコピーリンクがクリップボードにコピーされました!

10.1. ロギングの設定リンクのコピーリンクがクリップボードにコピーされました!

10.2. プロトコルロギングの有効化リンクのコピーリンクがクリップボードにコピーされました!

第11章 ファイルベースの設定リンクのコピーリンクがクリップボードにコピーされました!

11.1. ファイルの場所リンクのコピーリンクがクリップボードにコピーされました!

11.2. ファイル形式リンクのコピーリンクがクリップボードにコピーされました!

11.3. 設定オプションリンクのコピーリンクがクリップボードにコピーされました!

第12章 相互運用性リンクのコピーリンクがクリップボードにコピーされました!

12.1. 他の AMQP クライアントとの相互運用リンクのコピーリンクがクリップボードにコピーされました!

12.2. Red Hat build of Apache Qpid JMS との相互運用リンクのコピーリンクがクリップボードにコピーされました!

JMS メッセージ型

12.3. AMQ Broker への接続リンクのコピーリンクがクリップボードにコピーされました!

付録A サブスクリプションの使用リンクのコピーリンクがクリップボードにコピーされました!

A.1. アカウントへのアクセスリンクのコピーリンクがクリップボードにコピーされました!

A.2. サブスクリプションのアクティベートリンクのコピーリンクがクリップボードにコピーされました!

A.3. リリースファイルのダウンロードリンクのコピーリンクがクリップボードにコピーされました!

A.4. パッケージ用システムの登録リンクのコピーリンクがクリップボードにコピーされました!

付録B 例で AMQ ブローカーの使用リンクのコピーリンクがクリップボードにコピーされました!

B.1. ブローカーのインストールリンクのコピーリンクがクリップボードにコピーされました!

B.2. ブローカーの起動リンクのコピーリンクがクリップボードにコピーされました!

B.3. キューの作成リンクのコピーリンクがクリップボードにコピーされました!

B.4. ブローカーの停止リンクのコピーリンクがクリップボードにコピーされました!

法律上の通知リンクのコピーリンクがクリップボードにコピーされました!

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

多様性を受け入れるオープンソースの強化

会社概要

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

多様性を受け入れるオープンソースの強化
リンクのコピー

第1章概要
リンクのコピー

1.1. 主な特長
リンクのコピー

1.2. サポートされる標準およびプロトコル
リンクのコピー

1.3. サポートされる構成
リンクのコピー

1.4. 用語および概念
リンクのコピー

1.5. このドキュメントの表記慣例
リンクのコピー

第2章インストール
リンクのコピー

2.1. 前提条件
リンクのコピー

2.2. Red Hat NPM レジストリーの使用
リンクのコピー

2.3. ブラウザーへのクライアントのデプロイ
リンクのコピー

2.4. サンプルのインストール
リンクのコピー

第3章スタートガイド
リンクのコピー

3.1. 前提条件
リンクのコピー

3.2. Red Hat Enterprise Linux での Hello World の実行
リンクのコピー

3.3. Microsoft Windows での Hello World の実行
リンクのコピー

第4章例
リンクのコピー

4.1. メッセージの送信
リンクのコピー

4.2. メッセージの受信
リンクのコピー

第5章 API の使用
リンクのコピー

5.1. メッセージングイベントの処理
リンクのコピー

5.2. イベント関連のオブジェクトへのアクセス
リンクのコピー

5.3. コンテナーの作成
リンクのコピー

5.4. コンテナーアイデンティティーの設定
リンクのコピー

第6章ネットワーク接続
リンクのコピー

6.1. 外向き接続の作成
リンクのコピー

6.2. 再接続の設定
リンクのコピー

6.3. フェイルオーバーの設定
リンクのコピー

6.4. 内向き接続の許可
リンクのコピー

第7章セキュリティー
リンクのコピー

7.1. SSL/TLS を使用した接続のセキュリティー保護
リンクのコピー

7.2. ユーザーとパスワードを使用した接続
リンクのコピー

7.3. SASL 認証の設定
リンクのコピー

第8章送信者と受信者
リンクのコピー

8.1. オンデマンドでのキューとトピックの作成
リンクのコピー

8.2. 永続サブスクリプションの作成
リンクのコピー

8.3. 共有サブスクリプションの作成
リンクのコピー

第9章エラー処理
リンクのコピー

9.1. 接続およびプロトコルエラーの処理
リンクのコピー

第10章ロギング
リンクのコピー

10.1. ロギングの設定
リンクのコピー

10.2. プロトコルロギングの有効化
リンクのコピー

第11章ファイルベースの設定
リンクのコピー

11.1. ファイルの場所
リンクのコピー

11.2. ファイル形式
リンクのコピー

11.3. 設定オプション
リンクのコピー

第12章相互運用性
リンクのコピー

12.1. 他の AMQP クライアントとの相互運用
リンクのコピー

12.2. Red Hat build of Apache Qpid JMS との相互運用
リンクのコピー

12.3. AMQ Broker への接続
リンクのコピー

付録A サブスクリプションの使用
リンクのコピー

A.1. アカウントへのアクセス
リンクのコピー

A.2. サブスクリプションのアクティベート
リンクのコピー

A.3. リリースファイルのダウンロード
リンクのコピー

A.4. パッケージ用システムの登録
リンクのコピー

付録B 例で AMQ ブローカーの使用
リンクのコピー

B.1. ブローカーのインストール
リンクのコピー

B.2. ブローカーの起動
リンクのコピー

B.3. キューの作成
リンクのコピー

B.4. ブローカーの停止
リンクのコピー

法律上の通知
リンクのコピー